package com.cjfather.redis.steam.consumers;

import org.springframework.data.redis.connection.stream.MapRecord;
import org.springframework.data.redis.stream.StreamListener;

/**
 * 
 * @author: todd
 * @date:   2023-08-08
 */

public interface ConsumerI  extends StreamListener<String, MapRecord<String, Object, Object>>{

	void setConsumerName(String consumer);

	void setGroup(String group);
	
}
